package com.rocketmq.test;

import com.rocketmq.comsumer.MyPushConsumer;
import org.apache.rocketmq.client.apis.ClientException;

import java.io.IOException;

public class Dem1Consumer {

    public static void main(String[] args) throws ClientException, IOException {
        MyPushConsumer consumer = new MyPushConsumer();
        consumer.consumer("demo-async-group", "demo-fifo");
    }
}